#include "../mq_server/mq_channel.hpp"

using namespace pxt_mq;
using namespace mq_server;

int main()
{
    ChannelManager::ptr cmp = std::make_shared<ChannelManager>();

    cmp->OpenChannel("c1",  muduo::net::TcpConnectionPtr(), std::make_shared<ConsumerManager>(), ProtobufCodecPtr(),
        std::make_shared<VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"), threadpool::ptr());

    return 0;
}